package com.example.demo.consumer;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author wangyy
 * @date 2022/7/10
 */
public interface OmsSink {

    String CHANNEL_NAME_1 = "channel-name-1";

    String CHANNEL_NAME_2 = "channel-name-2";

    @Input(OmsSink.CHANNEL_NAME_1)
    SubscribableChannel inputChannel1();

    @Input(OmsSink.CHANNEL_NAME_2)
    SubscribableChannel inputChannel2();

}
